var rxjs = require('rxjs');
var Rx = require('rx').Rx;
// http://blogs.msdn.com/b/ie/archive/2011/09/11/asynchronous-programming-in-javascript-with-promises.aspx?ocid=aff-n-in-loc--RV

var obs = Rx.Observable.Create(function(obs) { 
  Rx.Observable.Interval(1000).Subscribe(function(tick) { 
    obs.OnNext("doug");
  });
});

obs.Subscribe(function(item) {
  console.log(item);
});